package com.suppor.rpc.core.util;

import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;
import java.util.concurrent.atomic.AtomicLong;

import com.suppor.rpc.core.trans.RpcResponse;

public class RpcServiceUtil {

    public static final ConcurrentMap<Long, RpcFuture<RpcResponse>> responseFuture = new ConcurrentHashMap<>();
    public static final AtomicLong REQUEST_ID_GENERATE = new AtomicLong(0);

    public static String serviceKey(String serviceName, String version) {
        return String.join("#", serviceName, version);
    }
}
